from typing import Dict
from airflow.models import BaseOperator
from airflow.utils.decorators import apply_defaults


class DorisLoadOperator(BaseOperator):

    @apply_defaults
    def __init__(
            self,
            *,
            content: str,
            **kwargs,
    ) -> None:
        super().__init__(**kwargs)
        self.content = content

    def execute(self, context: Dict):
        print(context)
